package com.ysh.spring.event.listener;

import com.ysh.spring.event.pojo.HZ;
import org.springframework.context.event.EventListener;
import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.stereotype.Component;

/**
 * 袁胜虎 on 2022/8/29 19:05
 */
@Component
@EnableAsync//开启异步
public class XF {
    @EventListener//事件的监听者,只要有人发出HZ类型的事件,这个方法就会执行
    @Async//当前方法是在异步中执行的
    public void onEvent(HZ hz){
        try {
            Thread.sleep(20000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.err.println("消防员收到了通知,在"+hz.getAddress()+"这个地方发生了火灾"+Thread.currentThread().getName());
    }
}
